package vip.ifmm.lehouse.mq.service.api.mock;

import org.apache.rocketmq.client.producer.SendResult;
import vip.ifmm.lehouse.common.dto.ServerResponse;
import vip.ifmm.lehouse.common.enums.status.MqStatus;
import vip.ifmm.lehouse.mq.service.api.RocketMqService;

/**
 * 消息队列服务接口
 *
 * @author Red
 * email: 1318944013@qq.com
 * date: 2019/6/17 21:36
 */

public class RocketMqServiceMock implements RocketMqService {


    @Override
    public ServerResponse<SendResult> send(String topic, String tags, String msg) {
        return ServerResponse.response(MqStatus.SEND_SERVICE_IS_UNAVAILABLE);
    }

    @Override
    public ServerResponse<SendResult> sendOrderly(String topic, String tags, String msg, Integer queueIndex) {
        return ServerResponse.response(MqStatus.SEND_SERVICE_IS_UNAVAILABLE);
    }
}
